package com.niit.mobileDevide.Gender;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Partitioner;

public class GenderPartitioner extends Partitioner<Text, Text> {

    @Override
    public int getPartition(Text key, Text value, int numPartitions) {
        // 根据性别进行分区，假设键是以性别-设备型号的形式组成的
        char genderChar = key.toString().charAt(0);
        if (genderChar == 'M') {
            return 0; // 男性分配到第一个分区
        } else if (genderChar == 'F') {
            return 1; // 女性分配到第二个分区
        } else {
            // 对于无效的性别，分配到默认分区0
            return 0;
        }
    }
}